package com.wwg.threads.binghe.concurrent.executor.callable;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class CallableTest {

    private static final Logger LOGGER = LoggerFactory.getLogger(CallableTest.class);

    public static void main(String[] args) throws InterruptedException {
        CallableHandler callableHandler = new CallableHandler();
        Thread t = new Thread(new TaskA(callableHandler, 1));
        t.start();
        t.join();
        TaskResult<ResultParams> taskResult = callableHandler.getTaskResult();
        LOGGER.info("主线程获取回调结果：{}",taskResult);
    }
}
